package org.xqh.study.mq.kafka;

import java.time.Duration;

/**
 * @ClassName KafkaDict
 * @Description TODO
 * @Author xuqianghui
 * @Date 2020/10/10 15:46
 * @Version 1.0
 */
public class KafkaDict {

    public static final String MQ_ADDRESS_COLLECTION = "192.168.188.131:9092";			//kafka地址
//    public static final String MQ_ADDRESS_COLLECTION = "47.103.38.174:9092";			//yunmao test kafka地址  不可用
//    public static final String MQ_ADDRESS_COLLECTION = "139.224.52.6:9092";			//yunmao dev kafka地址
//    public static final String MQ_ADDRESS_COLLECTION = "8.210.10.84:9061";			//kafka地址
//    public static final String CONSUMER_TOPIC = "topicDemo";						//消费者连接的topic
    public static final String CONSUMER_TOPIC = "shimaoiot.canal.space.check";						//消费者连接的topic
//    public static final String CONSUMER_TOPIC = "shimaoiot.canal.space";						//消费者连接的topic
    public static final String PRODUCER_TOPIC = "canal_space_topic";						//生产者连接的topic
    public static final String CONSUMER_GROUP_ID = "test";								//groupId，可以分开配置
    public static final String CONSUMER_ENABLE_AUTO_COMMIT = "true";				//是否自动提交（消费者）
    public static final String CONSUMER_AUTO_COMMIT_INTERVAL_MS = "1000";
    public static final String CONSUMER_SESSION_TIMEOUT_MS = "30000";				//连接超时时间
    public static final int CONSUMER_MAX_POLL_RECORDS = 10;							//每次拉取数
    public static final Duration CONSUMER_POLL_TIME_OUT = Duration.ofMillis(3000);	//拉去数据超时时间

}
